package _01_event_bus._1_0_3_actor

import akka.actor.{ActorRef, ActorSystem}
import akka.event.{ActorClassifier, ActorEventBus, ManagedActorClassification}

/**
  * actor 分类器
  *
  * @author galudisu
  */
final case class Notification(ref:ActorRef,id:Int)
class ActorBusImpl(val system:ActorSystem) extends ActorEventBus with ActorClassifier with ManagedActorClassification{
  override type Event = Notification
  override protected def classify(event: Notification): Classifier = event.ref
  override protected def mapSize: Int = 128
}
